package com.flink.datastreamapi.aggregation;

import com.flink.datastreamapi.bean.WaterSensor;
import org.apache.flink.api.common.functions.ReduceFunction;

public class WaterSensorMapFunction implements ReduceFunction<WaterSensor> {
    @Override
    public WaterSensor reduce(WaterSensor value1, WaterSensor value2) throws Exception {
        return null;
    }
}
